package com.dxwan.observables.math;



import hu.akarnokd.rxjava2.math.MathObservable;
import io.reactivex.Observable;


public class App {
    public static void main(String[] args) {
        Observable.just(1,2,3,4,5)
                .count();

        Observable<Integer> o = Observable.range(1,200);
        MathObservable.averageFloat(o)
                .subscribe( System.out::println);

        MathObservable.max(o)
                .subscribe( System.out::println);

        MathObservable.min(o)
                .subscribe( System.out::println);

        MathObservable.sumInt(o)
                .subscribe( System.out::println);

    }
}
